3edb38294674db29029d9d3a6ae8686837148512,src/water/hdfs/PersistHdfs.java,PersistHdfs,fileLoad,#Value#,146

Before Change


          skip += value_len;
        }
      }
      s = _fs.open(getPathForKey(k));
      ByteStreams.skipFully(s, skip);
      ByteStreams.readFully(s, b);
      assert v.isPersisted();

After Change


          skip += value_len;
        }
      }
      Path p = getPathForKey(k);
      FileSystem fs = FileSystem.get(p.toUri(), CONF);
      s = fs.open(p);
      ByteStreams.skipFully(s, skip);
      ByteStreams.readFully(s, b);